# """celery服务启动文件"""
# from celery import Celery
#
# # 1.创建celery客户端对象
# celery_app = Celery('meiduo')
#
# # 2.加载配置信息(将来任务存储的仓库)
# celery_app.config_from_object('celery_tasks.config')
#
# # 3.自动注册异步任务(将来那些 任务可以在仓库中存放)
# celery_app.autodiscover_tasks(['celery_tasks.sms'])


from celery import Celery

# 为celery使用django配置文件进行设置
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'meiduo_mall.settings.dev'

# 创建celery应用
celery_app = Celery('meiduo')

# 导入celery配置
celery_app.config_from_object('celery_tasks.config')

# 自动注册celery任务
# celery_app.autodiscover_tasks(['celery_tasks.sms'])
celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])